package com.reload.reaactor;

import reactor.core.publisher.Flux;

/**
 * @Date: 2024/12/5 14:36
 * @Author: jianchenlong
 * @Description: 日志
 */
public class Log {
    public static void main(String[] args) {
        Flux.concat(Flux.just(1, 2, 3), Flux.just(4, 5, 6))
                .filter(item -> item > 3)
                .log()
                .subscribe(System.out::println);

    }
}
